<?php
require_once(dirname(__FILE__)."/../include/db_mysql.php");

function init_get_homepageid( $partyid, $email_account )
{
	$sql = new SqlClass;
	//连接数据库
	$sql->connect();

	//通过partyid得到party中该条记录的homePageId字段内容
    $sql_command = "SELECT homePageId FROM  `party` where partyId='$partyid';";
	$r = $sql->exec_sql( $sql_command );//保存执行sql的结果

	$row = mysql_fetch_array($r);
	if( $row['homePageId']===NULL || $row['homePageId']==='' ) //说明得到的homepageid为空，即该条记录中homepageid字段没有值，为空。
	{
		//给email_account加上域名
		$pageUrl = "http://127.0.0.1:8001/shanghu_page.php?email_account=".$email_account;

		//获得当前时间
		date_default_timezone_set('PRC');
		$dt = date("Y-m-d   H:i:s");

		$sql_command = "INSERT INTO  `party`.`partypageinfo` (
	`pageUrl`,
	`refreshDateTime`
	)
	VALUES (
	'$pageUrl',  '$dt'
	);"; //向partypageinfo表插入一条记录

		$r = $sql->exec_sql( $sql_command );//保存执行sql的结果

		$pageId = mysql_insert_id();//得到刚才插入的那条记录的pageId

		if( $pageId == false ) //数据库出问题，插入失败。
		{
			$sql->close();
			return '';//按约定返回空串
		}

		//到party表，找到partyid对应的那条记录，并把pageId插入到该记录的homePageId字段。
		$sql_command = "UPDATE  `party`.`party` SET  `homePageId` =  '$pageId' WHERE  `party`.`partyId` = '$partyid';";
		$r = $sql->exec_sql( $sql_command );//保存执行sql的结果

		$sql->close();

		if( $r ) //sql执行没有出错
		{
			return $pageId;
		}
		else
		{
			return '';
		}
	}
	else //说明得到的homepageid不为空，直接返回即可。
	{
		$sql->close();
		return $row['homePageId'];
	}
}
?>